fc0675d4e8268c55b38716f3a81e63522ce72bac,src/main/java/com/ociweb/pronghorn/network/ClientConnection.java,ClientConnection,registerForUse,#Selector#Pipe[]#boolean#,220
Before Change
while (--i>=0) {
Pipe<NetPayloadSchema> pipe = handshakeBegin[i];
if (PipeWriter.tryWriteFragment(pipe, NetPayloadSchema.MSG_PLAIN_210) ) {
PipeWriter.writeLong(pipe, NetPayloadSchema.MSG_PLAIN_210_FIELD_CONNECTIONID_201, getId());
PipeWriter.writeLong(pipe, NetPayloadSchema.MSG_PLAIN_210_FIELD_POSITION_206, SSLUtil.HANDSHAKE_POS); //signal that WRAP is needed
PipeWriter.writeBytes(pipe, NetPayloadSchema.MSG_PLAIN_210_FIELD_PAYLOAD_204, EMPTY);
PipeWriter.publishWrites(pipe);
//we did it, hurrah
break;
After Change
while (--j>=0) {
Pipe<NetPayloadSchema> pipe = handshakeBegin[c];
assert(null!=pipe);
if (Pipe.hasRoomForWrite(pipe)) {
// logger.info("request wrap for id {} to pipe {}",getId(), pipe);
int size = Pipe.addMsgIdx(pipe, NetPayloadSchema.MSG_PLAIN_210);
Pipe.addLongValue(getId(), pipe);
Pipe.addLongValue(System.currentTimeMillis(), pipe);
Pipe.addLongValue(SSLUtil.HANDSHAKE_POS, pipe);
Pipe.addByteArray(EMPTY, 0, 0, pipe);
Pipe.confirmLowLevelWrite(pipe, size);
Pipe.publishWrites(pipe);
//we did it, hurrah
break;